package com.dlink.sqljobsync;

import java.util.HashMap;
import java.util.Map;

public class DlinkSqlConst {


    /**
     * flink cdc To KafKa
     * kafka 属性映射转换
     */
    public static final Map<String, String> DlinkCdcSqlToKafkaMap = new HashMap<String, String>(){
        {
            put("connector", "#1");
            put("topic", "#2");
            put("properties.bootstrap.servers", "#3");
            put("scan.startup.mode", "#4");
            put("format", "#5");
        }
    };

    /**
     * flink cdc To Mysql
     * Mysql 属性映射转换
     */
    public static final Map<String, String> DlinkCdcSqlToMysqlMap = new HashMap<String, String>(){
        {
            put("connector", "#1");
            put("hostname", "#2");
            put("port", "#3");
            put("username", "#4");
            put("password", "#5");
            put("database-name", "#6");
            put("table-name", "#7");
            put("server-id", "#8");
            put("scan.incremental.snapshot.enabled", "#9");
        }
    };
}
